package com.ouyangtao.spark.product;

import org.apache.spark.sql.api.java.UDF1;

/**
 * 去除随机前缀
 */
public class RemoveRandomPrefixUDF implements UDF1<String,String> {
    private static final long serialVersionUID = 1L;
    @Override
    public String call(String val) throws Exception {
        String[] split = val.split("_");
        return split[1];
    }
}
